package com.leilei.broadcaststate.common;

import org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig;

/**
 * @author lei
 * @version 1.0
 * @date 2021/3/24 21:45
 */
public class RabbitConfigUtil {
    public static RMQConnectionConfig getConnectionConfig() {
        return new RMQConnectionConfig.Builder()
                .setHost("10.50.40.116")
                .setPort(5673)
                .setUserName("admin")
                .setPassword("admin")
                .setVirtualHost("/")
                .build();
    }

}
